﻿

namespace IDEAMS.core.queue
{
    public class OPM_MsgDispatcher : Dispatcher<OPM_MsgWorker, QueueDataType, QueueData>
    {
        public override QueueDataType GetDataType(QueueData data)
        {
            QueueDataType key = data.type;
            return key;
        }

        public override void Notify(OPM_MsgWorker worker, QueueData data)
        {
            worker.recvQueue.TryEnqueue(data, 3000);
        }
    }
}
